package flinkemp;

import org.apache.flink.streaming.api.functions.source.SourceFunction;

import java.util.ArrayList;
import java.util.Arrays;
import java.util.Random;

public class EmpFun implements SourceFunction<Emp> {
    private Boolean running = true;

    public void run(SourceContext<Emp> order) throws Exception {

        Integer oid = 0;
        Integer eid = 1001;
        Random random = new Random();
        String[] name = {"张伟", "王芳", "李娜", "李强", "王秀英",
                "李敏", "张敏", "刘伟", "张秀英", "王伟",
                "张丽", "李静", "王静", "张静", "李丽",
                "王丽", "刘洋", "张勇", "王勇", "李明",
                "张杰", "王杰", "李杰", "刘杰", "张强", "王强",
                "李强", "刘强", "张军", "王军", "李军",
                "刘军", "张华", "王华", "李华", "刘华",
                "张秀兰", "王秀兰", "李秀兰", "刘秀兰", "张桂英",
                "王桂英", "李桂英", "刘桂英", "张萍", "王萍",
                "李萍", "刘萍", "张雪", "王雪", "李雪",
                "刘雪", "张燕", "王燕", "李燕", "刘燕",
                "张慧", "王慧", "李慧", "刘慧", "张玉",
                "王玉", "李玉", "刘玉", "张英", "王英",
                "李英", "刘英", "张红", "王红", "李红",
                "刘红", "张兰", "王兰", "李兰", "刘兰",
                "张刚", "王刚", "李刚", "刘刚", "张健",
                "王健", "李健", "刘健", "张波", "王波",
                "李波", "刘波", "张超", "王超", "李超",
                "刘超", "张鑫", "王鑫", "李鑫", "刘鑫"};
        String[] post = {"大数据工程师", "前端工程师", "java工程师"};

        while (running) {
            order.collect(new Emp(
                    oid++,
                    eid++,
                    name[random.nextInt(name.length)],
                    post[random.nextInt(post.length)],
                    random.nextDouble() * 5000 + 5000,
                    (random.nextInt(4) + 1) * 10
            ));
            Thread.sleep(1000);
        }
    }

    @Override
    public void cancel() {
        running = false;
    }
}
